package 双Value类型

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object union {
    //连接 不会去重
    def main(args: Array[String]): Unit = {

        val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("WordCount")

        val sc = new SparkContext(config)

        val listRDD: RDD[Int] = sc.makeRDD(List(1, 2, 3, 4, 5))

        val ArrayRDD: RDD[Int] = sc.parallelize(Array(5, 6, 7))

        val unionRDD: RDD[Int] = listRDD.union(ArrayRDD)

        unionRDD.collect().foreach(println)

        val unionRDD2: RDD[Int] = ArrayRDD.union(listRDD)

        unionRDD2.collect().foreach(println)


    }

}
